package com.dems.task.job;

import com.dems.service.AsyncDeviceService;
import com.xxl.job.core.handler.annotation.XxlJob;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * XxlJob开发示例（Bean模式）
 *
 * 开发步骤：
 *      1、任务开发：在Spring Bean实例中，开发Job方法；
 *      2、注解配置：为Job方法添加注解 "@XxlJob(value="自定义jobhandler名称", init = "JobHandler初始化方法", destroy = "JobHandler销毁方法")"，注解value值对应的是调度中心新建任务的JobHandler属性的值。
 *      3、执行日志：需要通过 "XxlJobHelper.log" 打印执行日志；
 *      4、任务结果：默认任务结果为 "成功" 状态，不需要主动设置；如有诉求，比如设置任务结果为失败，可以通过 "XxlJobHelper.handleFail/handleSuccess" 自主设置任务结果；
 *从格物平台同步设备数据至动环系统
 * @author xuxueli 2019-12-11 21:52:51
 */
@Slf4j
@Component
public class AsyncDeviceTask {
    @Autowired
    private AsyncDeviceService asyncDeviceService;

    /**
     * 同步产品信息
     * */
    @XxlJob("asyncProductTask")
    public void asyncProductTask(){
        //同步产品信息
        asyncDeviceService.asyncProductList();
    }

    /**
     * 同步设备信息
     * */
    @XxlJob("asyncDeviceTask")
    public void asyncDeviceTask(){
        //同步设备列表
        asyncDeviceService.asyncDeviceList();
        //同步设备基本信息
        asyncDeviceService.asyncDeviceBaseInfos();
    }

    @XxlJob("asyncDeviceProperty")
    public void asyncDeviceProperty(){
        //同步设备属性信息
        asyncDeviceService.asyncDeviceMonitorData();
    }

    /**
     * 同步物模型信息
     * */
    @XxlJob("asyncDeviceModel")
    public void asyncDeviceModel(){
        //同步物模型信息
        asyncDeviceService.asyncDeviceMonitorData();
    }
}
